🎖️GitЯра🎖️ - /page/blob.mu

T8b949e/*

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.repository

Tff7b72import T7ee787androidx.paging.Pager

Tff7b72import T7ee787androidx.paging.PagingConfig

Tff7b72import T7ee787androidx.paging.PagingData

Tff7b72import T7ee787androidx.paging.map

Tff7b72import T7ee787kotlinx.coroutines.flow.Flow

Tff7b72import T7ee787kotlinx.coroutines.flow.flatMapLatest

Tff7b72import T7ee787kotlinx.coroutines.flow.map

Tff7b72import T7ee787kotlinx.coroutines.flow.mapLatest

Tff7b72import T7ee787kotlinx.coroutines.withContext

Tff7b72import T7ee787okio.ByteString.Companion.toByteString

Tff7b72import T7ee787org.koin.core.annotation.Single

Tff7b72import T7ee787org.meshtastic.core.database.DatabaseProvider

Tff7b72import T7ee787org.meshtastic.core.database.entity.PacketEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.toReaction

Tff7b72import T7ee787org.meshtastic.core.di.CoroutineDispatchers

Tff7b72import T7ee787org.meshtastic.core.model.ContactSettings

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.Message

Tff7b72import T7ee787org.meshtastic.core.model.MessageStatus

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.model.Reaction

Tff7b72import T7ee787org.meshtastic.proto.ChannelSettings

Tff7b72import T7ee787org.meshtastic.proto.PortNum

Tff7b72import T7ee787org.meshtastic.core.database.entity.ContactSettings Tff7b72as Te6edf3ContactSettingsEntity

Tff7b72import T7ee787org.meshtastic.core.database.entity.Packet Tff7b72as Te6edf3RoomPacket

Tff7b72import T7ee787org.meshtastic.core.database.entity.ReactionEntity Tff7b72as Te6edf3RoomReaction

Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository Tff7b72as Te6edf3SharedPacketRepository

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffLongParameterListTa5d6ff"Tb4b4b4)

Tf0883e@Single

Tff7b72class T56d364PacketRepositoryImplTb4b4b4(Tff7b72private Tff7b72val Te6edf3dbManagerTb4b4b4: Te6edf3DatabaseProviderTb4b4b4, Tff7b72private Tff7b72val Te6edf3dispatchersTb4b4b4: Te6edf3CoroutineDispatchersTb4b4b4) Tb4b4b4:

Te6edf3SharedPacketRepository Tb4b4b4{

Tff7b72override Tff7b72fun Td2a8ffgetWaypointsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72>Tff7b72> Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDb

Tb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getAllWaypointsFlowTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3list Tff7b72-Tff7b72> Te6edf3listTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetContactsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3MapTff7b72<Tffa657StringTb4b4b4, Te6edf3DataPacketTff7b72>Tff7b72> Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDb

Tb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactKeysTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3map Tff7b72-Tff7b72> Te6edf3mapTb4b4b4.Te6edf3mapValues Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetContactsPagedTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3DataPacketTff7b72>Tff7b72> Tff7b72= Te6edf3PagerTb4b4b4(

Te6edf3config Tff7b72=

Te6edf3PagingConfigTb4b4b4(

Te6edf3pageSize Tff7b72= Te6edf3CONTACTS_PAGE_SIZETb4b4b4,

Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3initialLoadSize Tff7b72= Te6edf3CONTACTS_PAGE_SIZETb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactKeysPagedTb4b4b4(Tb4b4b4) Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tb4b4b4.Te6edf3flow

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72> Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3data Tb4b4b4} Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetMessageCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessageCountTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetUnreadCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetUnreadCountFlowTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountFlowTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetFirstUnreadMessageUuidTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657Long?Tff7b72> Tff7b72=

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFirstUnreadMessageUuidTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffhasUnreadMessagesTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657BooleanTff7b72> Tff7b72=

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3hasUnreadMessagesTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetUnreadCountTotalTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getUnreadCountTotalTb4b4b4(Tb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearUnreadCountTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3timestampTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3clearUnreadCountTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3timestampTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearAllUnreadCountsTb4b4b4(Tb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3clearAllUnreadCountsTb4b4b4(Tb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateLastReadMessageTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3messageUuidTb4b4b4: Tffa657LongTb4b4b4, Te6edf3lastReadTimestampTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3current Tff7b72= Te6edf3daoTb4b4b4.Te6edf3getContactSettingsTb4b4b4(Te6edf3contactTb4b4b4)

Tff7b72val Te6edf3existingTimestamp Tff7b72= Te6edf3currentTff7b72?.Te6edf3lastReadMessageTimestamp Tff7b72?: Tffa657LongTb4b4b4.Te6edf3MIN_VALUE

Tff7b72if Tb4b4b4(Te6edf3lastReadTimestamp Tff7b72<Tff7b72= Te6edf3existingTimestampTb4b4b4) Tb4b4b4{

Tff7b72returnTf0883e@withContext

Tb4b4b4}

Tff7b72val Te6edf3updated Tff7b72=

Tb4b4b4(Te6edf3current Tff7b72?: Te6edf3ContactSettingsEntityTb4b4b4(Te6edf3contact_key Tff7b72= Te6edf3contactTb4b4b4)Tb4b4b4)Tb4b4b4.Te6edf3copyTb4b4b4(

Te6edf3lastReadMessageUuid Tff7b72= Te6edf3messageUuidTb4b4b4,

Te6edf3lastReadMessageTimestamp Tff7b72= Te6edf3lastReadTimestampTb4b4b4,

Tb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3upsertContactSettingsTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3updatedTb4b4b4)Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetQueuedPacketsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72> Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getQueuedPacketsTb4b4b4(Tb4b4b4) Tb4b4b4}

Tff7b72suspend Tff7b72fun Td2a8ffinsertRoomPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsavePacketTb4b4b4(

Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3receivedTimeTb4b4b4: Tffa657LongTb4b4b4,

Te6edf3readTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4,

Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packetToSave Tff7b72=

Te6edf3RoomPacketTb4b4b4(

Te6edf3uuid Tff7b72= T79c0ff0LTb4b4b4,

Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,

Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3port_num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4,

Te6edf3contact_key Tff7b72= Te6edf3contactKeyTb4b4b4,

Te6edf3received_time Tff7b72= Te6edf3receivedTimeTb4b4b4,

Te6edf3read Tff7b72= Te6edf3readTb4b4b4,

Te6edf3data Tff7b72= Te6edf3packetTb4b4b4,

Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3snrTb4b4b4,

Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rssiTb4b4b4,

Te6edf3hopsAway Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hopsAwayTb4b4b4,

Te6edf3filtered Tff7b72= Te6edf3filteredTb4b4b4,

Tb4b4b4)

Te6edf3insertRoomPacketTb4b4b4(Te6edf3packetToSaveTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetMessagesFromTb4b4b4(

Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3limitTb4b4b4: Tffa657Int?Tb4b4b4,

Te6edf3includeFilteredTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3flow Tff7b72=

Tff7b72when Tb4b4b4{

Te6edf3limit Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3limitTb4b4b4)

Tff7b72!Te6edf3includeFiltered Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4, Te6edf3includeFiltered Tff7b72= Tff7b72falseTb4b4b4)

Tff7b72else Tff7b72-Tff7b72> Te6edf3daoTb4b4b4.Te6edf3getMessagesFromTb4b4b4(Te6edf3contactTb4b4b4)

Tb4b4b4}

Te6edf3flowTb4b4b4.Te6edf3mapLatest Tb4b4b4{ Te6edf3packets Tff7b72-Tff7b72>

Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)

Tff7b72val Te6edf3replyIds Tff7b72= Te6edf3packetsTb4b4b4.Te6edf3mapNotNull Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3id Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4} Tb4b4b4}Tb4b4b4.Te6edf3distinctTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3replyMap Tff7b72= Te6edf3batchGetPacketsByIdsTb4b4b4(Te6edf3replyIdsTb4b4b4)

Te6edf3packetsTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}

Tff7b72val Te6edf3originalMessage Tff7b72= Te6edf3replyIdTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3replyMapTff7b72[Tffa657itTff7b72] Tb4b4b4}Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetMessagesFromPagedTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4, Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72=

Te6edf3PagerTb4b4b4(

Te6edf3config Tff7b72=

Te6edf3PagingConfigTb4b4b4(

Te6edf3pageSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,

Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3initialLoadSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessagesFromPagedTb4b4b4(Te6edf3contactTb4b4b4) Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tb4b4b4.Te6edf3flow

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72>

Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)

Tff7b72val Te6edf3replyCache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntity?Tff7b72>Tb4b4b4(Tb4b4b4)

Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}

Tff7b72val Te6edf3originalMessage Tff7b72=

Te6edf3replyId

Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3replyCacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getPacketByPacketIdInternalTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}

Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message

Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetMessagesFromPagedTb4b4b4(

Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3includeFilteredTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3PagingDataTff7b72<Te6edf3MessageTff7b72>Tff7b72> Tff7b72= Te6edf3PagerTb4b4b4(

Te6edf3config Tff7b72=

Te6edf3PagingConfigTb4b4b4(

Te6edf3pageSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,

Te6edf3enablePlaceholders Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3initialLoadSize Tff7b72= Te6edf3MESSAGES_PAGE_SIZETb4b4b4,

Tb4b4b4)Tb4b4b4,

Te6edf3pagingSourceFactory Tff7b72= Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getMessagesFromPagedTb4b4b4(Te6edf3contactKeyTb4b4b4, Te6edf3includeFilteredTb4b4b4)

Tb4b4b4}Tb4b4b4,

Tb4b4b4)

Tb4b4b4.Te6edf3flow

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3pagingData Tff7b72-Tff7b72>

Tff7b72val Te6edf3cachedGetNode Tff7b72= Te6edf3memoizeTb4b4b4(Te6edf3getNodeTb4b4b4)

Tff7b72val Te6edf3replyCache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntity?Tff7b72>Tb4b4b4(Tb4b4b4)

Te6edf3pagingDataTb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

Tff7b72val Te6edf3message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72val Te6edf3replyId Tff7b72= Te6edf3messageTb4b4b4.Te6edf3replyIdTff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72!Tff7b72= T79c0ff0 Tb4b4b4}

Tff7b72val Te6edf3originalMessage Tff7b72=

Te6edf3replyId

Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3replyCacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getPacketByPacketIdInternalTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}

Tff7b72?.Te6edf3toMessageTb4b4b4(Te6edf3cachedGetNodeTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3originalMessage Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3messageTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3originalMessage Tff7b72= Te6edf3originalMessageTb4b4b4) Tff7b72else Te6edf3message

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateMessageStatusTb4b4b4(Te6edf3dTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3mTb4b4b4: Te6edf3MessageStatusTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateMessageStatusTb4b4b4(Te6edf3dTb4b4b4, Te6edf3mTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateMessageIdTb4b4b4(Te6edf3dTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3idTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateMessageIdTb4b4b4(Te6edf3dTb4b4b4, Te6edf3idTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByIdTb4b4b4(Te6edf3idTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3DataPacket? Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByIdTb4b4b4(Te6edf3idTb4b4b4)Tff7b72?.Te6edf3data Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3DataPacket? Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tff7b72?.Te6edf3packetTff7b72?.Te6edf3data

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffgetPacketByPacketIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffbatchGetPacketsByIdsTb4b4b4(Te6edf3idsTb4b4b4: Te6edf3ListTff7b72<Tffa657IntTff7b72>Tb4b4b4)Tb4b4b4: Te6edf3MapTff7b72<Tffa657IntTb4b4b4, Te6edf3PacketEntityTff7b72> Tff7b72= Tff7b72if Tb4b4b4(Te6edf3idsTb4b4b4.Te6edf3isEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3emptyMapTb4b4b4(Tb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getPacketsByPacketIdsTb4b4b4(Te6edf3idsTb4b4b4)Tb4b4b4.Te6edf3associateBy Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3packetTb4b4b4.Te6edf3packetId Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffmemoizeTb4b4b4(Te6edf3getNodeTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4)Tb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657String?Tb4b4b4) Tff7b72-Tff7b72> Te6edf3Node Tb4b4b4{

Tff7b72val Te6edf3cache Tff7b72= Te6edf3mutableMapOfTff7b72<Tffa657String?Tb4b4b4, Te6edf3NodeTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72return Tb4b4b4{ Te6edf3id Tff7b72-Tff7b72> Te6edf3cacheTb4b4b4.Te6edf3getOrPutTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4{ Te6edf3getNodeTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4} Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertTb4b4b4(

Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4,

Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3receivedTimeTb4b4b4: Tffa657LongTb4b4b4,

Te6edf3readTb4b4b4: Tffa657BooleanTb4b4b4,

Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4,

Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3packetToSave Tff7b72=

Te6edf3RoomPacketTb4b4b4(

Te6edf3uuid Tff7b72= T79c0ff0LTb4b4b4,

Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,

Te6edf3packetId Tff7b72= Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3port_num Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTypeTb4b4b4,

Te6edf3contact_key Tff7b72= Te6edf3contactKeyTb4b4b4,

Te6edf3received_time Tff7b72= Te6edf3receivedTimeTb4b4b4,

Te6edf3read Tff7b72= Te6edf3readTb4b4b4,

Te6edf3data Tff7b72= Te6edf3packetTb4b4b4,

Te6edf3snr Tff7b72= Te6edf3packetTb4b4b4.Te6edf3snrTb4b4b4,

Te6edf3rssi Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rssiTb4b4b4,

Te6edf3hopsAway Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hopsAwayTb4b4b4,

Te6edf3filtered Tff7b72= Te6edf3filteredTb4b4b4,

Tb4b4b4)

Te6edf3insertRoomPacketTb4b4b4(Te6edf3packetToSaveTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3DataPacketTb4b4b4, Te6edf3routingErrorTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Unit Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

T8b949e// Match on key fields that identify the packet, rather than the entire data object

Te6edf3daoTb4b4b4.Te6edf3findPacketsWithIdTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3idTb4b4b4)

Tb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3id Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3id Tff7b72&Tff7b72& Tffa657itTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3from Tff7b72&Tff7b72& Tffa657itTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3to Tb4b4b4}

Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3existing Tff7b72-Tff7b72>

Tff7b72val Te6edf3updated Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3routingError Tff7b72>Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{

Te6edf3existingTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3data Tff7b72= Te6edf3packetTb4b4b4, Te6edf3routingError Tff7b72= Te6edf3routingErrorTb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3existingTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3data Tff7b72= Te6edf3packetTb4b4b4)

Tb4b4b4}

Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3updatedTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffinsertReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3ReactionTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3toEntityTb4b4b4(Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3ReactionTb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3findReactionsWithIdTb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3packetIdTb4b4b4)

Tb4b4b4.Te6edf3find Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3userId Tff7b72=Tff7b72= Te6edf3reactionTb4b4b4.Te6edf3userTb4b4b4.Te6edf3id Tff7b72&Tff7b72& Tffa657itTb4b4b4.Te6edf3emoji Tff7b72=Tff7b72= Te6edf3reactionTb4b4b4.Te6edf3emoji Tb4b4b4}

Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3toEntityTb4b4b4(Tffa657itTb4b4b4.Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Tb4b4b4} Tff7b72?: Tffa657Unit

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetReactionByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3Reaction? Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getReactionByPacketIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tff7b72?.Te6edf3toReaction Tb4b4b4{ Tff7b72null Tb4b4b4}

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8fffindPacketsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3DataPacketTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findPacketsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3data Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8fffindPacketsWithIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findPacketsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8fffindReactionsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Te6edf3ListTff7b72<Te6edf3ReactionTff7b72> Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findReactionsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4)Tb4b4b4.Te6edf3toReaction Tb4b4b4{ Tff7b72null Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8fffindReactionsWithIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3findReactionsWithIdTb4b4b4(Te6edf3packetIdTb4b4b4) Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffCyclomaticComplexMethodTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateSFPPStatusTb4b4b4(

Te6edf3packetIdTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3fromTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3toTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3hashTb4b4b4: Te6edf3ByteArrayTb4b4b4,

Te6edf3statusTb4b4b4: Te6edf3MessageStatusTb4b4b4,

Te6edf3rxTimeTb4b4b4: Tffa657LongTb4b4b4,

Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4,

Tb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3packets Tff7b72= Te6edf3findPacketsWithIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4)

Tff7b72val Te6edf3reactions Tff7b72= Te6edf3findReactionsWithIdInternalTb4b4b4(Te6edf3packetIdTb4b4b4)

Tff7b72val Te6edf3fromId Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3nodeNumToDefaultIdTb4b4b4(Te6edf3fromTb4b4b4)

Tff7b72val Te6edf3isFromLocalNode Tff7b72= Te6edf3myNodeNum Tff7b72!Tff7b72= Tff7b72null Tff7b72&Tff7b72& Te6edf3from Tff7b72=Tff7b72= Te6edf3myNodeNum

Tff7b72val Te6edf3toId Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3to Tff7b72=Tff7b72= T79c0ff0 Tff7b72|Tff7b72| Te6edf3to Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3NODENUM_BROADCASTTb4b4b4) Tb4b4b4{

Te6edf3DataPacketTb4b4b4.Te6edf3ID_BROADCAST

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3DataPacketTb4b4b4.Te6edf3nodeNumToDefaultIdTb4b4b4(Te6edf3toTb4b4b4)

Tb4b4b4}

Tff7b72val Te6edf3hashByteString Tff7b72= Te6edf3hashTb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Te6edf3packetsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

T8b949e// For sent messages, from is stored as ID_LOCAL, but SFPP packet has node number

Tff7b72val Te6edf3fromMatches Tff7b72=

Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3fromId Tff7b72|Tff7b72| Tb4b4b4(Te6edf3isFromLocalNode Tff7b72&Tff7b72& Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_LOCALTb4b4b4)

Te6edf3coTb4b4b4.Te6edf3touchlabTb4b4b4.Te6edf3kermitTb4b4b4.Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{

Ta5d6ff"Ta5d6ffSFPP match check: packetFrom=Tffd700${Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3fromTffd700}Ta5d6ff fromId=Tffd700$Te6edf3fromIdTa5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffisFromLocal=Tffd700$Te6edf3isFromLocalNodeTa5d6ff fromMatches=Tffd700$Te6edf3fromMatchesTa5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffpacketTo=Tffd700${Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3toTffd700}Ta5d6ff toId=Tffd700$Te6edf3toIdTa5d6ff toMatches=Tffd700${Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3toIdTffd700}Ta5d6ff"

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3fromMatches Tff7b72&Tff7b72& Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3toIdTb4b4b4) Tb4b4b4{

T8b949e// If it's already confirmed, don't downgrade it to routing

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_CONFIRMED Tff7b72&Tff7b72& Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_ROUTINGTb4b4b4) Tb4b4b4{

Tff7b72returnTf0883e@forEach

Tb4b4b4}

Tff7b72val Te6edf3newTime Tff7b72= Tff7b72if Tb4b4b4(Te6edf3rxTime Tff7b72> T79c0ff0Tb4b4b4) Te6edf3rxTime Tff7b72* Te6edf3MILLISECONDS_IN_SECOND Tff7b72else Te6edf3packetTb4b4b4.Te6edf3received_time

Tff7b72val Te6edf3updatedData Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3statusTb4b4b4, Te6edf3sfppHash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3time Tff7b72= Te6edf3newTimeTb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3data Tff7b72= Te6edf3updatedDataTb4b4b4, Te6edf3sfpp_hash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3received_time Tff7b72= Te6edf3newTimeTb4b4b4)Tb4b4b4)

Tb4b4b4}

Te6edf3reactionsTb4b4b4.Te6edf3forEach Tb4b4b4{ Te6edf3reaction Tff7b72-Tff7b72>

Tff7b72val Te6edf3reactionFrom Tff7b72= Te6edf3reactionTb4b4b4.Te6edf3userId

T8b949e// For sent reactions, from is stored as ID_LOCAL, but SFPP packet has node number

Tff7b72val Te6edf3fromMatches Tff7b72= Te6edf3reactionFrom Tff7b72=Tff7b72= Te6edf3fromId Tff7b72|Tff7b72| Tb4b4b4(Te6edf3isFromLocalNode Tff7b72&Tff7b72& Te6edf3reactionFrom Tff7b72=Tff7b72= Te6edf3DataPacketTb4b4b4.Te6edf3ID_LOCALTb4b4b4)

Tff7b72val Te6edf3toMatches Tff7b72= Te6edf3reactionTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Te6edf3toId

Te6edf3coTb4b4b4.Te6edf3touchlabTb4b4b4.Te6edf3kermitTb4b4b4.Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{

Ta5d6ff"Ta5d6ffSFPP reaction match check: reactionFrom=Tffd700$Te6edf3reactionFromTa5d6ff fromId=Tffd700$Te6edf3fromIdTa5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffisFromLocal=Tffd700$Te6edf3isFromLocalNodeTa5d6ff fromMatches=Tffd700$Te6edf3fromMatchesTa5d6ff Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffreactionTo=Tffd700${Te6edf3reactionTb4b4b4.Te6edf3toTffd700}Ta5d6ff toId=Tffd700$Te6edf3toIdTa5d6ff toMatches=Tffd700$Te6edf3toMatchesTa5d6ff"

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3fromMatches Tff7b72&Tff7b72& Tb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3to Tff7b72=Tff7b72= Tff7b72null Tff7b72|Tff7b72| Te6edf3toMatchesTb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_CONFIRMED Tff7b72&Tff7b72& Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_ROUTINGTb4b4b4) Tb4b4b4{

Tff7b72returnTf0883e@forEach

Tb4b4b4}

Tff7b72val Te6edf3newTime Tff7b72= Tff7b72if Tb4b4b4(Te6edf3rxTime Tff7b72> T79c0ff0Tb4b4b4) Te6edf3rxTime Tff7b72* Te6edf3MILLISECONDS_IN_SECOND Tff7b72else Te6edf3reactionTb4b4b4.Te6edf3timestamp

Tff7b72val Te6edf3updatedReaction Tff7b72=

Te6edf3reactionTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3statusTb4b4b4, Te6edf3sfpp_hash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3timestamp Tff7b72= Te6edf3newTimeTb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3updatedReactionTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateSFPPStatusByHashTb4b4b4(Te6edf3hashTb4b4b4: Te6edf3ByteArrayTb4b4b4, Te6edf3statusTb4b4b4: Te6edf3MessageStatusTb4b4b4, Te6edf3rxTimeTb4b4b4: Tffa657LongTb4b4b4)Tb4b4b4: Tffa657Unit Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3dao Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3hashByteString Tff7b72= Te6edf3hashTb4b4b4.Te6edf3toByteStringTb4b4b4(Tb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3findPacketBySfppHashTb4b4b4(Te6edf3hashByteStringTb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3packet Tff7b72-Tff7b72>

T8b949e// If it's already confirmed, don't downgrade it

Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_CONFIRMED Tff7b72&Tff7b72& Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_ROUTINGTb4b4b4) Tb4b4b4{

Tff7b72returnTf0883e@let

Tb4b4b4}

Tff7b72val Te6edf3newTime Tff7b72= Tff7b72if Tb4b4b4(Te6edf3rxTime Tff7b72> T79c0ff0Tb4b4b4) Te6edf3rxTime Tff7b72* Te6edf3MILLISECONDS_IN_SECOND Tff7b72else Te6edf3packetTb4b4b4.Te6edf3received_time

Tff7b72val Te6edf3updatedData Tff7b72= Te6edf3packetTb4b4b4.Te6edf3dataTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3statusTb4b4b4, Te6edf3sfppHash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3time Tff7b72= Te6edf3newTimeTb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3packetTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3data Tff7b72= Te6edf3updatedDataTb4b4b4, Te6edf3sfpp_hash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3received_time Tff7b72= Te6edf3newTimeTb4b4b4)Tb4b4b4)

Tb4b4b4}

Te6edf3daoTb4b4b4.Te6edf3findReactionBySfppHashTb4b4b4(Te6edf3hashByteStringTb4b4b4)Tff7b72?.Te6edf3let Tb4b4b4{ Te6edf3reaction Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3reactionTb4b4b4.Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_CONFIRMED Tff7b72&Tff7b72& Te6edf3status Tff7b72=Tff7b72= Te6edf3MessageStatusTb4b4b4.Te6edf3SFPP_ROUTINGTb4b4b4) Tb4b4b4{

Tff7b72returnTf0883e@let

Tb4b4b4}

Tff7b72val Te6edf3newTime Tff7b72= Tff7b72if Tb4b4b4(Te6edf3rxTime Tff7b72> T79c0ff0Tb4b4b4) Te6edf3rxTime Tff7b72* Te6edf3MILLISECONDS_IN_SECOND Tff7b72else Te6edf3reactionTb4b4b4.Te6edf3timestamp

Tff7b72val Te6edf3updatedReaction Tff7b72= Te6edf3reactionTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3status Tff7b72= Te6edf3statusTb4b4b4, Te6edf3sfpp_hash Tff7b72= Te6edf3hashByteStringTb4b4b4, Te6edf3timestamp Tff7b72= Te6edf3newTimeTb4b4b4)

Te6edf3daoTb4b4b4.Te6edf3updateTb4b4b4(Te6edf3updatedReactionTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteMessagesTb4b4b4(Te6edf3uuidListTb4b4b4: Te6edf3ListTff7b72<Tffa657LongTff7b72>Tb4b4b4) Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Tff7b72for Tb4b4b4(Te6edf3chunk Tff7b72in Te6edf3uuidListTb4b4b4.Te6edf3chunkedTb4b4b4(Te6edf3DELETE_CHUNK_SIZETb4b4b4)Tb4b4b4) Tb4b4b4{

T8b949e// Fetch DAO per chunk to avoid holding a stale reference if the active DB switches

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteMessagesTb4b4b4(Te6edf3chunkTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteContactsTb4b4b4(Te6edf3contactListTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteContactsTb4b4b4(Te6edf3contactListTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffdeleteWaypointTb4b4b4(Te6edf3idTb4b4b4: Tffa657IntTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteWaypointTb4b4b4(Te6edf3idTb4b4b4) Tb4b4b4}

Tff7b72suspend Tff7b72fun Td2a8ffdeleteTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4}

Tff7b72suspend Tff7b72fun Td2a8ffupdateTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3RoomPacketTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetContactSettingsTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3MapTff7b72<Tffa657StringTb4b4b4, Te6edf3ContactSettingsTff7b72>Tff7b72> Tff7b72= Te6edf3dbManagerTb4b4b4.Te6edf3currentDb

Tb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactSettingsTb4b4b4(Tb4b4b4) Tb4b4b4}

Tb4b4b4.Te6edf3map Tb4b4b4{ Te6edf3map Tff7b72-Tff7b72> Te6edf3mapTb4b4b4.Te6edf3mapValues Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3toSharedTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetContactSettingsTb4b4b4(Te6edf3contactTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3ContactSettings Tff7b72= Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getContactSettingsTb4b4b4(Te6edf3contactTb4b4b4)Tff7b72?.Te6edf3toSharedTb4b4b4(Tb4b4b4) Tff7b72?: Te6edf3ContactSettingsTb4b4b4(Te6edf3contactTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetMuteUntilTb4b4b4(Te6edf3contactsTb4b4b4: Te6edf3ListTff7b72<Tffa657StringTff7b72>Tb4b4b4, Te6edf3untilTb4b4b4: Tffa657LongTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setMuteUntilTb4b4b4(Te6edf3contactsTb4b4b4, Te6edf3untilTb4b4b4) Tb4b4b4}

Tff7b72suspend Tff7b72fun Td2a8ffinsertReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3RoomReactionTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3insertTb4b4b4(Te6edf3reactionTb4b4b4) Tb4b4b4}

Tff7b72suspend Tff7b72fun Td2a8ffupdateReactionTb4b4b4(Te6edf3reactionTb4b4b4: Te6edf3RoomReactionTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateTb4b4b4(Te6edf3reactionTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72fun Td2a8ffgetFilteredCountFlowTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Tffa657IntTff7b72> Tff7b72=

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3flatMapLatest Tb4b4b4{ Te6edf3db Tff7b72-Tff7b72> Te6edf3dbTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFilteredCountFlowTb4b4b4(Te6edf3contactKeyTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffgetFilteredCountTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Int Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3getFilteredCountTb4b4b4(Te6edf3contactKeyTb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffsetContactFilteringDisabledTb4b4b4(Te6edf3contactKeyTb4b4b4: Tffa657StringTb4b4b4, Te6edf3disabledTb4b4b4: Tffa657BooleanTb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3setContactFilteringDisabledTb4b4b4(Te6edf3contactKeyTb4b4b4, Te6edf3disabledTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearPacketDBTb4b4b4(Tb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3deleteAllTb4b4b4(Tb4b4b4) Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffmigrateChannelsByPSKTb4b4b4(Te6edf3oldSettingsTb4b4b4: Te6edf3ListTff7b72<Te6edf3ChannelSettingsTff7b72>Tb4b4b4, Te6edf3newSettingsTb4b4b4: Te6edf3ListTff7b72<Te6edf3ChannelSettingsTff7b72>Tb4b4b4) Tff7b72=

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{

Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3migrateChannelsByPSKTb4b4b4(Te6edf3oldSettingsTb4b4b4, Te6edf3newSettingsTb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffupdateFilteredBySenderTb4b4b4(Te6edf3senderIdTb4b4b4: Tffa657StringTb4b4b4, Te6edf3filteredTb4b4b4: Tffa657BooleanTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3pattern Tff7b72= Ta5d6ff"Ta5d6ff%Ta5d6ff\"Ta5d6fffromTa5d6ff\"Ta5d6ff:Ta5d6ff\"Tffd700${Te6edf3senderIdTffd700}Ta5d6ff\"Ta5d6ff%Ta5d6ff"

Te6edf3withContextTb4b4b4(Te6edf3dispatchersTb4b4b4.Te6edf3ioTb4b4b4) Tb4b4b4{ Te6edf3dbManagerTb4b4b4.Te6edf3currentDbTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3packetDaoTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3updateFilteredBySenderTb4b4b4(Te6edf3patternTb4b4b4, Te6edf3filteredTb4b4b4) Tb4b4b4}

Tb4b4b4}

Tff7b72private Tff7b72fun Te6edf3orgTb4b4b4.Td2a8ffmeshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3databaseTb4b4b4.Te6edf3daoTb4b4b4.Te6edf3PacketDaoTb4b4b4.Te6edf3getAllWaypointsFlowTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3FlowTff7b72<Te6edf3ListTff7b72<Te6edf3RoomPacketTff7b72>Tff7b72> Tff7b72=

Te6edf3getAllPacketsTb4b4b4(Te6edf3PortNumTb4b4b4.Te6edf3WAYPOINT_APPTb4b4b4.Te6edf3valueTb4b4b4)

Tff7b72private Tff7b72fun Te6edf3ContactSettingsEntityTb4b4b4.Td2a8fftoSharedTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3ContactSettingsTb4b4b4(

Te6edf3contactKey Tff7b72= Te6edf3contact_keyTb4b4b4,

Te6edf3muteUntil Tff7b72= Te6edf3muteUntilTb4b4b4,

Te6edf3lastReadMessageUuid Tff7b72= Te6edf3lastReadMessageUuidTb4b4b4,

Te6edf3lastReadMessageTimestamp Tff7b72= Te6edf3lastReadMessageTimestampTb4b4b4,

Te6edf3filteringDisabled Tff7b72= Te6edf3filteringDisabledTb4b4b4,

Te6edf3isMuted Tff7b72= Te6edf3isMutedTb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72fun Te6edf3ReactionTb4b4b4.Td2a8fftoEntityTb4b4b4(Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4) Tff7b72= Te6edf3RoomReactionTb4b4b4(

Te6edf3myNodeNum Tff7b72= Te6edf3myNodeNumTb4b4b4,

Te6edf3replyId Tff7b72= Te6edf3replyIdTb4b4b4,

Te6edf3userId Tff7b72= Te6edf3userTb4b4b4.Te6edf3idTb4b4b4,

Te6edf3emoji Tff7b72= Te6edf3emojiTb4b4b4,

Te6edf3timestamp Tff7b72= Te6edf3timestampTb4b4b4,

Te6edf3snr Tff7b72= Te6edf3snrTb4b4b4,

Te6edf3rssi Tff7b72= Te6edf3rssiTb4b4b4,

Te6edf3hopsAway Tff7b72= Te6edf3hopsAwayTb4b4b4,

Te6edf3packetId Tff7b72= Te6edf3packetIdTb4b4b4,

Te6edf3status Tff7b72= Te6edf3statusTb4b4b4,

Te6edf3routingError Tff7b72= Te6edf3routingErrorTb4b4b4,

Te6edf3relays Tff7b72= Te6edf3relaysTb4b4b4,

Te6edf3relayNode Tff7b72= Te6edf3relayNodeTb4b4b4,

Te6edf3to Tff7b72= Te6edf3toTb4b4b4,

Te6edf3channel Tff7b72= Te6edf3channelTb4b4b4,

Te6edf3sfpp_hash Tff7b72= Te6edf3sfppHashTb4b4b4,

Tb4b4b4)

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72const Tff7b72val Te6edf3CONTACTS_PAGE_SIZE Tff7b72= T79c0ff3T79c0ff0

Tff7b72private Tff7b72const Tff7b72val Te6edf3MESSAGES_PAGE_SIZE Tff7b72= T79c0ff5T79c0ff0

Tff7b72private Tff7b72const Tff7b72val Te6edf3DELETE_CHUNK_SIZE Tff7b72= T79c0ff5T79c0ff0T79c0ff0

Tff7b72private Tff7b72const Tff7b72val Te6edf3MILLISECONDS_IN_SECOND Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0L

Tb4b4b4}